package com.Reactor3参考文档.math;

import reactor.core.publisher.Flux;

public class Reduce {

	// 对流中包含的所有元素进行累积操作，得到一个包含计算结果的Mono序列，具体的累积操作也是通过一个BiFunction来实现的
	public static void main(String[] args) {
		Flux.range(1, 10).reduce((x, y) -> x + y).subscribe(System.out::println);
		// reduceWith用来在进行reduce操作时指定一个初始值
		Flux.range(1, 10).reduceWith(() -> 5, (x, y) -> x + y).subscribe(System.out::println);
	}

}
